const { Server } = require('socket.io');
const socketio = {}
socketio.getSocketio = function(server){
    
    let io = new Server(server,{cors:true});
    io.sockets.on("connection", (socket) => {
        // socket.on("joinRoom",(room)=>{
        //   socket.join(room)
        //   roomid = room
        //   // console.log("房间------------",room)
        // })
        // 群聊的房间
        // socket.on("grouproom",(room)=>{
        //   socket.join(room)
        //   grouproomid = room
        //   // console.log("群聊的房间------------",room)
        
        // })
        // 监听群聊发送的消息
        socket.on("sendMessage",async(obj)=>{
          console.log("前发送过来的数据",obj);
          io.emit("receive-group-message",obj)
        })
        // socket.on("send-chat-message", async(obj) => {
        //     await messageModel.create(obj)
            
        // //   console.log("前端发送过来的数据", obj);
        //   // console.log("前端发送过来的数据",obj);
        //   // 发送消息给客户端
        //   // console.log("房间号2222222-----",roomid)
        //   io.to(roomid).emit("chat-message", obj);
        //   // io.emit("chat-message", obj);
        // });
      });
}
module.exports =socketio


